package com.lonely.framework.websocket;

import cn.hutool.extra.spring.SpringUtil;
import org.springframework.messaging.simp.SimpMessagingTemplate;

/**
 * @author : 黄志标
 * @date: 2025/8/21 10:55
 * @description: websocket工具类
 */
public class WebSocketUtil {

    private static final SimpMessagingTemplate MESSAGING_TEMPLATE = SpringUtil.getBean(SimpMessagingTemplate.class);

    /**
     * 发送消息给指定用户
     *
     * @param targetUser  接收人
     * @param destination 监听的频道
     * @param message     发送的消息
     */
    public static void sendToUser(String targetUser, String destination, Object message) {
        MESSAGING_TEMPLATE.convertAndSendToUser(
                targetUser,
                destination,
                message
        );
    }

    /**
     * 广播发送消息
     *
     * @param destination 监听的频道
     * @param message     发送的消息
     */
    public static void sendAll(String destination, Object message) {
        MESSAGING_TEMPLATE.convertAndSend(destination, message);
    }


}
